122c6e92824ebee923ebb36b65d1a4813c916d6a,storio-content-resolver/src/main/java/com/pushtorefresh/storio/contentresolver/operations/get/PreparedGetObject.java,PreparedGetObject,createObservable,#,119
Before Change
return storIOContentResolver
.observeChangesOfUri(query.uri()) // each change triggers executeAsBlocking
.map(MapSomethingToExecuteAsBlocking.newInstance(this))
.startWith(Observable.create(OnSubscribeExecuteAsBlocking.newInstance(this))) // start stream with first query result
.subscribeOn(Schedulers.io());
}
After Change
return storIOContentResolver
.observeChangesOfUri(query.uri()) // each change triggers executeAsBlocking
.map(MapSomethingToExecuteAsBlocking.newInstance(this))
.startWith(Observable.create(OnSubscribeExecuteAsBlocking.newInstance(this))) // start stream with first query result
.onBackpressureLatest()
.subscribeOn(Schedulers.io());
}
/**